package JDBC;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class DATABASE implements JDBC{
	
	    static Connection conn;
	    static Statement sta;
	    static ResultSet rs;
	    
	    //获得Connection类型对象
	public static Connection getConnection(){
		try {
			
		Class.forName(DRIVER);
		conn = DriverManager.getConnection(URL,USER,PASSWORD);
		System.out.println("连接成功");
		return conn;
		} catch (ClassNotFoundException e) {
			// TODO 自动生成的 catch 块
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO 自动生成的 catch 块
			System.out.println("连接失败");
			e.printStackTrace();
		}return null;
	//以上就是连接数据库并执行了sql语句
		
        }
	//获得Statement类型对象
	public static Statement openStatement(){
		try {
			sta=getConnection().createStatement();
			return sta;
		} catch (SQLException e) {
			// TODO 自动生成的 catch 块
			e.printStackTrace();
		}
		return null;
	}
	
	//完成数据的更新操作
	public static int update(String sql){
		try {
			return openStatement().executeUpdate(sql);
		} catch (SQLException e) {
			// TODO 自动生成的 catch 块
			e.printStackTrace();
		}
		return -1;
	}
	



	//完成数据的查询操作
	public static ResultSet query(String sql){
		try {
			rs=openStatement().executeQuery(sql);
		} catch (SQLException e) {
			// TODO 自动生成的 catch 块
			e.printStackTrace();
		}
		return rs;
	}
	



	//释放资源 close
		public static void close(Connection conn){
			if(conn!=null){
				try{
					conn.close();
				}catch(Exception e){
					e.printStackTrace();
				}
			}
		}
		
		public static void main(String[] args) throws Exception {
			Connection conn = DATABASE.getConnection();
			System.out.println(conn.getCatalog());
		}
}
